d65223002c9f951623dd6b24494408a1f2026824,src/main/java/com/continuuity/fabric/engine/memory/MemoryQueue.java,MemoryQueue,pop,#QueueConsumer#QueuePartitioner#,48

Before Change


  throws InterruptedException {
    // Anything in the queue at all?  Wait for a push if so
    if (head == null) {
      waitForPush();
      return pop(consumer, partitioner);
    }
    

After Change


  throws InterruptedException {
    // Anything in the queue at all?  Wait for a push if so
    if (head == null) {
      if (sync) waitForPush(); else return null;
      return pop(consumer, partitioner);
    }